package cn.doitedu.flink.demo;

import java.sql.JDBCType;
import java.util.List;

public abstract class MyOperator<T> {

    private String sql;
    private int fieldsCnts;
    private List<JDBCType> tableFieldsTypes;

    public MyOperator(String sql, int fieldsCnts, List<JDBCType> tableFieldsTypes) {
        this.sql = sql;
        this.fieldsCnts = fieldsCnts;
        this.tableFieldsTypes = tableFieldsTypes;
    }

    public abstract Object[] op(T o);

    public String getSql() {
        return sql;
    }

    public void setSql(String sql) {
        this.sql = sql;
    }

    public int getFieldsCnts() {
        return fieldsCnts;
    }

    public void setFieldsCnts(int fieldsCnts) {
        this.fieldsCnts = fieldsCnts;
    }

    public List<JDBCType> getTableFieldsTypes() {
        return tableFieldsTypes;
    }

    public void setTableFieldsTypes(List<JDBCType> tableFieldsTypes) {
        this.tableFieldsTypes = tableFieldsTypes;
    }




}
